b6c99e0901fde933b273be1833fc70b06a32173f,integration/src/integration/java/pl/allegro/tech/hermes/integration/BatchDeliveryTest.java,BatchDeliveryTest,shouldDeliverAvroMessagesAsJsonBatch,#,101
Before Change
AvroUser user = new AvroUser("Bob", 50, "blue");
Topic topic = topic("batch.avro.topic")
.withValidation(true)
.withMessageSchema(user.getSchemaAsString())
.withContentType(AVRO).build();
operations.buildTopic(topic);
operations.createBatchSubscription(topic, HTTP_ENDPOINT_URL, buildBatchPolicy()
After Change
// given
AvroUser user = new AvroUser("Bob", 50, "blue");
Topic topic = topic("batch.avro.topic")
.withValidation(true)
.withContentType(AVRO).build();
operations.buildTopic(topic);
operations.saveSchema(topic, user.getSchemaAsString());
operations.createBatchSubscription(topic, HTTP_ENDPOINT_URL, buildBatchPolicy()
.withBatchSize(2)